package com.shux.kafka.consumer;
/**
 * 描述：
 * 
 * <pre>HISTORY
 * ****************************************************************************
 *  ID   DATE           PERSON          REASON
 *  1    2017年9月19日      Simba.Hua         Create
 * ****************************************************************************
 * </pre>
 * @author Simba.Hua
 */
public class KafkaMessage<T> {
	private T message;
	private int partition;
	private long offset;
	public KafkaMessage(T message, int partition, long offset) {
		this.message = message;
		this.partition = partition;
		this.offset = offset;
	}
	@Override
	public String toString() {
		return "KafkaMessage [message=" + message + ", partition=" + partition
				+ ", offset=" + offset + "]";
	}
	public T getMessage() {
		return message;
	}
	public void setMessage(T message) {
		this.message = message;
	}
	public int getPartition() {
		return partition;
	}
	public void setPartition(int partition) {
		this.partition = partition;
	}
	public long getOffset() {
		return offset;
	}
	public void setOffset(long offset) {
		this.offset = offset;
	}
	
	
}
